package channelService

import (
	"gitee.com/fierce_wolf/go-fox-edge-common/commRedisRpc"
	"sync"
)

type channelService struct {
	channelName2Entity sync.Map
}

func (e *channelService) getChannelNames() map[string]interface{} {
	result := make(map[string]interface{})
	service.channelName2Entity.Range(func(key, ctx interface{}) bool {
		result[key.(string)] = ctx
		return true
	})

	return result
}

func (e *channelService) Execute(requestVO *commRedisRpc.ChannelRequestVO) (*commRedisRpc.ChannelRespondVO, error) {
	return execute.execute(requestVO)
}
